import zmq,time
context = zmq.Context.instance()
sock = context.socket(zmq.PUB)
sock.connect('tcp://127.0.0.1:4002')

t="aaaaa"*1024
while True:
  # t=raw_input()
  # print "send",t
  sock.send(t)
  time.sleep(0.001)
